
import ngrok
import time

import ngrok
import time

# Connect to ngrok for ingress
def connect(token, port, options):
    account = None
    if token is None:
        token = 'None'
    else:
        if ':' in token:
            # token = authtoken:username:password
            token, username, password = token.split(':', 2)
            account = f"{username}:{password}"

    # For all options see: https://github.com/ngrok/ngrok-py/blob/main/examples/ngrok-connect-full.py
    if not options.get('authtoken_from_env'):
        options['authtoken'] = token
    if account:
        options['basic_auth'] = account
    if not options.get('session_metadata'):
        options['session_metadata'] = 'stable-diffusion-webui'

    connected = False
    while not connected:
        try:
            public_url = ngrok.connect(f"127.0.0.1:{port}", **options).url()
            connected = True
        except Exception as e:
            print(f'Invalid ngrok authtoken? ngrok connection aborted due to: {e}\n'
                  f'Your token: {token}, get the right one on https://dashboard.ngrok.com/get-started/your-authtoken')
            time.sleep(5)  # Add a delay before attempting to reconnect

    print(f'ngrok connected to localhost:{port}! URL: {public_url}\n')
